#数据库主要用来查询参数，数据清理
"""作业"""

import pymysql
from common.read_yaml import get_yaml_filepath,configs_data
db = configs_data['db']
print(db)
def get_db_conn():
    conn = pymysql.connect(host=db['host'],   #数据库地址
                           port=3306,     #端口
                           user=db['user_name'],  #账号
                           passwd=db['password'], # 密码
                           database =['db_name'], #要操作的数据库名
                           charset ='utf-8') #指定编码格式
    return conn

def query_db(sql):
    conn = get_db_conn() #获取连接
    cur = conn.cursor(cursor=pymysql.cursors.DictCursor)  #建立游标
    cur.execute(sql) #执行SQL
    conn.commit()
    result = cur.fetchone()  #获取查询结果
    print(result)
    cur.close() #关闭游标
    conn.close() #关闭连接
    return result

def delete_db(sql):
    conn = get_db_conn() #获取连接
    cur = conn.cursor(cursor=pymysql.cursors.DictCursor)  #建立游标
    cur.execute(sql) #执行SQL
    conn.commit()
    result = cur.fetchone()  #获取查询结果
    print(result)
    cur.close() #关闭游标
    conn.close() #关闭连接
    return result

if __name__ == '__main__':
    query_db(sql="SELECT {列} FROM {表名} WHERE {条件}")
    # delete_db(sql=)